from common.variables import TimeFrameType


def get_kline_topic(symbol: str, timeframe: TimeFrameType) -> str:
    return f"kline_{symbol}_{timeframe}".replace(":", "_").replace("/", "_")


def get_factor_topic(symbol: str, tfname: str, timeframe: TimeFrameType) -> str:
    return f"factor_{symbol}_{tfname}_{timeframe}".replace(":", "_").replace("/", "_")
